# 生产者　创建的包中的文件必须叫tasks.py
# 　１　所谓的生产者就是任务　　所谓的任务其实就是函数
        #  2. 这个函数必须要被celery的实例对象的task装饰器装饰　
        # ３．　这个函数要让celery自动检测到



'''
消费者
１．消费者通过一条指令　，在虚拟环境中设置就可以了
语法：　celery -A proj worker -l info

'''



# celery 把三者串联起来

from celery import Celery
import os
# 0. 在创建celery 之前我们需要加载ｄｊａｎｇｏ工程的配置文件
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")

# 1. Celery 将三者串联起来了, 先创建一个celery
# main 相当于给celery实例设置一个唯一的名字
app = Celery(main='celery_tasks')

# 2 设置我们的中间人,让celery加载中间人配置信息
# 文件路径
app.config_from_object('celery_tasks.config')
# 3 让celery 自动检测我们的任务
app.autodiscover_tasks(['celery_task.sms'])

# 4.运行　消费者
# １．消费者通过一条指令　，在虚拟环境中设置就可以了
# 　　　　语法：　celery -A proj worker -l info
# proj 指的是　celery实例对象的脚本路径
# 要在虚拟环境中运行该指令
# celery -A　celery_tasks.main worker -l info